package com.thh.create;

import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.TransportAddress;
import org.elasticsearch.transport.client.PreBuiltTransportClient;
import org.junit.Test;

import java.net.InetAddress;

/**
 * 演示ES的索引的创建
 */
public class App01_CreateIndex {

    @Test
    public void test1() throws Exception {
        //1、创建一个Settings对象，相当于一个配置信息。主要配置集群的名称。 cluster.name配置集群名称
        Settings settings = Settings.builder().put("cluster.name","elasticsearch").build();
        //2、创建一个客户端client对象。
        TransportClient client = new PreBuiltTransportClient(settings);
        //3、使用client对象创建一个索引库。
        client.addTransportAddress(new TransportAddress(InetAddress.getByName("127.0.0.1"),9300));
        /*
        prepareCreate: 创建索引
        get:  执行前面的操作
         */
        client.admin().indices().prepareCreate("xiaofeifei_index").get();
        //4、关闭client对象。
        client.close();
    }
}
